# from pyspark import SparkConf,SparkContext
# import os
# os.environ['PYSPARK_PYTHON']="C:/python的安装/python3.14.4/python.exe"
#
# conf=SparkConf().setMaster("local[*]").setAppName("test_spark")
# sc=SparkContext(conf=conf)
# rdd=sc.parallelize([1,2,3,4,5])
# rdd2=rdd.map(lambda x:x*10).map(lambda x:x+5)
# print(rdd2.collect())
#============================================
